package main

import (
	"log"
	_ "order_srv/basic/init"
	inits "order_srv/basic/init"
	"order_srv/handler/dao"
)

func main() {

	// 初始化WebSocket管理器
	inits.InitWebSocketManager()
	// 初始化导出配置
	inits.InitExportConfig()
	// 初始化预约订单定时处理器
	dao.StartScheduledOrderProcessor()
	// 启动导出任务消费者
	inits.StartExportConsumer() // 新增此行
	go func() {
		log.Println("正在启动导出任务消费者...")
		inits.StartExportConsumer()
	}()

	// 启动导出文件清理器
	go func() {
		log.Println("正在启动导出文件清理器...")
		inits.StartExportFileCleaner()
	}()
}
